@Override
public void on(Selector topic, TaskListener listener) {
on(topic, SubscriberTaskListener.create(listener));
}
@Override
* @param listener the listener to register
*/
public void register(final TaskListener listener) {
register(SelectorBuilder.selector(listener), listener);
}
/**